createRouteBuilder{
    @Override public void configure() throws Exception {
      from("direct:start").to(neo4jEndpoint).process(new Processor(){
        @Override public void process(        Exchange arg0) throws Exception {
          Long id=(Long)arg0.getIn().getHeader(Neo4jEndpoint.HEADER_RELATIONSHIP_ID);
          assertNotNull(id);
          Relationship r=neo.getRelationship(id);
}
configure{
      assertNotNull(id);
      Relationship r=neo.getRelationship(id);
      assertNotNull(r);
      assertEquals("tickles",r.getType().name());
).to(end);
}
process{
  Long id=(Long)arg0.getIn().getHeader(Neo4jEndpoint.HEADER_RELATIONSHIP_ID);
  Relationship r=neo.getRelationship(id);
  assertEquals("tickles",r.getType().name());
}
testCreateNodes{
  final int messageCount=100;
  end.expectedMessageCount(messageCount);
  Thread t=new Thread(new Runnable(){
      for (int k=0; k < messageCount; k++) {
        Node start=neo.createNode();
        Node end=neo.createNode();
        BasicRelationship r=new BasicRelationship(start,end,"tickles");
        template.sendBodyAndHeader(r,Neo4jEndpoint.HEADER_OPERATION,Neo4jOperation.CREATE_RELATIONSHIP);
  t.start();
}
run{
  for (int k=0; k < messageCount; k++) {
    Node start=neo.createNode();
    Node end=neo.createNode();
    template.sendBodyAndHeader(r,Neo4jEndpoint.HEADER_OPERATION,Neo4jOperation.CREATE_RELATIONSHIP);
}
